package com.niit.order.service.impl;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 自定义消息通道接口
 * @author yaojianfeng
 */
public interface MySink {
    String INPUT1 = "input1";
    String INPUT2 = "input2";

    /**
     * @return input channel.
     */
    @Input(MySink.INPUT1)
    SubscribableChannel input1();
    /**
     * @return input channel.
     */
    @Input(MySink.INPUT2)
    SubscribableChannel input2();
}
